package com.tonyodev.fetch2rx;

import io.reactivex.Flowable;
import io.reactivex.Observable;

/**
 * 操作流转换
 *
 * @param <T>
 * @since 2021-05-20
 */
public class Convertible<T> {
    private final Flowable<T> data;

    /**
     * 构造函数
     *
     * @param data 操作流
     */
    public Convertible(Flowable<T> data) {
        super();
        this.data = data;
    }

    /**
     * 获取数据源
     *
     * @return 数据源
     */
    public final Flowable<T> asFlowable() {
        return this.data;
    }

    /**
     * 获取数据源观察流
     *
     * @return 数据源观察流
     */
    public final Observable<T> asObservable() {
        return this.data.toObservable();
    }
}
